package com.java.code.kafka;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

/**
 * @author weichuanyuan
 * @e-mail wei.cy@bsoft.com.cn
 * @date 2021/10/20 10:26
 * @package com.java.code.kafka
 * @description
 */
@Service("unfinishTaskQueue")
@Slf4j
public class UnfinishTaskQueue implements MQBusinessHandler {
    @Override
    public boolean doBusiness(MQMessage<?> var1) {
        System.out.println("消息执行==>" + var1);
        return true;
    }
}
